package com.kafka_test.app.mapper;

import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Select;
import org.apache.ibatis.annotations.Update;
import org.springframework.stereotype.Repository;

import java.util.List;
import java.util.Map;

@Mapper
@Repository("OffsetMapper")
public interface OffsetMapper {

    @Insert("insert into ${tableName} (${column}) values(#{value})")
    void insertConsumer(String tableName, String column, Object value);
}
